package com.beta.mq.redis.consumer.annotation;

import java.lang.annotation.*;

/**
 * 批量获取
 * @author taofucheng
 * @date 2015/12/8.
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface OnBatchMessage {

    String topic();

    /**
     * 每批次获取最大值 默认 1000
     * @return
     */
    int limit() default 1000;

    /**
     * 休眠间隔 默认 1分钟
     * @return
     */
    long interval() default 60_000;
}
